package com.nimble.smile.service;


import rx.Observable;
import rx.Subscriber;

/**
 * Created by Administrator on 2016/8/12 0012.
 */
public class CheckLogoutOperator<T> implements Observable.Operator<T, T> {

    @Override
    public Subscriber<? super T> call(Subscriber<? super T> subscriber) {
        return new Subscriber<T>() {
            @Override
            public void onCompleted() {
                subscriber.onCompleted();
            }

            @Override
            public void onError(Throwable e) {
                subscriber.onError(e);
            }

            @Override
            public void onNext(T t) {

                subscriber.onNext(t);
            }
        };
    }
}
